/*
package cn.simon.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.listener.Topic;

*/
/**
 * @功能描述： rabbitMq配置类-主题模式
 * @Auther: simon-yi'an
 *//*

@Configuration
public class RabbitMqTopicConfig {
    private static final String QUEUE01 = "queue_topic01";
    private static final String QUEUE02 = "queue_topic02";
    private static final String TOPICEXCHANGE = "topicExchange";
    private static final String ROUTINGKEY01 = "*.simon.#";
    private static final String ROUTINGKEY02 = "#.simon.#";
    @Bean
    public Queue queue_topic01(){
        return new Queue(QUEUE01);
    }
    @Bean
    public Queue queue_topic02(){
        return new Queue(QUEUE02);
    }
    @Bean
    public TopicExchange topicExchange(){
        return new TopicExchange(TOPICEXCHANGE);
    }

    @Bean
    public Binding bindTopicExchange01(){
        return BindingBuilder.bind(queue_topic01()).to(topicExchange()).with(ROUTINGKEY01);
    }

    @Bean
    public Binding bindTopicExchange02(){
        return BindingBuilder.bind(queue_topic02()).to(topicExchange()).with(ROUTINGKEY02);
    }
}
*/
